Kafka consumer lag - Measure and reduce